package com.lds.memory.kafka.consumer.parallel;

import com.lds.memory.kafka.consumer.AbstractConsumer;
import com.lds.memory.kafka.topic.Topic;

public final class ConsumerBinder {
    private ConsumerBinder() {
    }

    public static void bind(Topic topic, Class<? extends AbstractConsumer> consumerClass) {
        ConsumeTopicTask task = new ConsumeTopicTask(topic, consumerClass);
        task.start();
    }

}
